from celery import Celery

# 为什么使用diango文件配置
# 因为发送短信重需要django短信配置信息

import os

# os.getenv() 获取系统全局变量，如果没有返回null指
if not os.getenv("DJANGO_SETTINGS_MODULE"):
    # 获取环境系统变量
    os.environ["DJANGO_SETTINGS_MODULE"] = "meidou_all.settings.dev"
    # os.environ["DJANGO_SETTINGS_MODULE"] = "meiduo_all.settings.dev"

# 在创建实例之前一定先加载在其他路径的包配置，如果实例之后再去加载，会返现找不到该模块，因为他会从/开始找
# 创建crlery
app = Celery("meiduo")



# 导入crlery的环境配置
app.config_from_object("celery_tasks.config")

# 自动注册#这是个列表可以添加多个任务
# 声明获取异步任务的队列[目录中必须有一个tasks.py文件，这个就是任务文件]
app.autodiscover_tasks(["celery_tasks.sms", "celery_tasks.email"])


# 在终端下执行一下命令
# celery -A  主程序路径  worker -1 info

# 在meiduo_all/meiduo_all下运行
# celery -A celery_tasks.mian worker -l info
# celery -A celery_tasks.main worker -l info
